package nbcp.db.mq

import nbcp.base.comm.JsonMap
import org.slf4j.LoggerFactory
import org.springframework.amqp.core.*
import org.springframework.data.redis.listener.adapter.MessageListenerAdapter
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory
import org.springframework.amqp.rabbit.core.RabbitAdmin
import org.springframework.amqp.rabbit.core.RabbitTemplate
import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
import nbcp.base.extend.*
import nbcp.base.utils.SpringUtil
import nbcp.db.mongo.mor
import nbcp.db.mongo.*
import java.time.LocalDateTime


object mqr {
    // 以 exchange 为主
    class SystemGroup {
        val broadcast = MqSenderProxy<String>("broadcast")
    }

    val sys = SystemGroup()
    private val logger = LoggerFactory.getLogger(this::class.java)
}